package com.bw.gmall.realtime.dwd.db.app;

import com.bw.gmall.realtime.common.base.BaseSQLApp;
import com.bw.gmall.realtime.common.constant.Constant;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class DwdTradeOrderCancelDetail extends BaseSQLApp {
    public static void main(String[] args) {
        new DwdTradeOrderCancelDetail().start(10015,4, Constant.TOPIC_DWD_TRADE_ORDER_CANCEL);
    }
    @Override
    public void handle(StreamExecutionEnvironment env, StreamTableEnvironment tableEnv, String groupId) {
        /**
         *  取消订单的数据：topic_db  过滤条件  Type=Update and  and old["status"] is not null and data['order_status']=1003
         *  订单表详情表做Join  用什么Join 考虑状态保存时间嘛  15+5s
         *  保存数据：订单详情
         *  order_id    status
         *     1          1003
         *  id  order_id  sku_id
         *  1    1          10
         *  2    1          20
         */


    }
}
